14fb1446c655860fd20723f3713ca8ab0d6111a0,foxtrot-core/src/main/java/com/flipkart/foxtrot/core/datastore/impl/hbase/HBaseUtil.java,HBaseUtil,create,#HbaseConfig#,35

Before Change



    public static Configuration create(final HbaseConfig hbaseConfig) throws IOException {
        Configuration configuration = HBaseConfiguration.create();
        if(hbaseConfig.isSecure()
                && null != hbaseConfig.getKeytabFileName()
                && !hbaseConfig.getKeytabFileName().isEmpty()) {
            File file = new File(hbaseConfig.getKeytabFileName());
            if (file.exists()) {
                configuration.addResource(new File(hbaseConfig.getCoreSite()).toURI().toURL());
                configuration.addResource(new File(hbaseConfig.getHdfsSite()).toURI().toURL());
                configuration.addResource(new File(hbaseConfig.getHbasePolicy()).toURI().toURL());
                configuration.addResource(new File(hbaseConfig.getHbaseSite()).toURI().toURL());
                configuration.set("hbase.master.kerberos.principal", hbaseConfig.getAuthString());
                configuration.set("hadoop.kerberos.kinit.command", hbaseConfig.getKinitPath());
                UserGroupInformation.setConfiguration(configuration);

After Change


            configuration.addResource(new File(hbaseConfig.getHbasePolicy()).toURI().toURL());
        }

        if (isValidFile(hbaseConfig.getHbaseSite())) {
            configuration.addResource(new File(hbaseConfig.getHbaseSite()).toURI().toURL());
        }

        if (hbaseConfig.isSecure() && isValidFile(hbaseConfig.getKeytabFileName())) {
            configuration.set("hbase.master.kerberos.principal", hbaseConfig.getAuthString());
            configuration.set("hadoop.kerberos.kinit.command", hbaseConfig.getKinitPath());
            UserGroupInformation.setConfiguration(configuration);